package com.sdses.flink.apps;

import com.alibaba.fastjson2.JSONObject;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.io.Serializable;

/**
 * @author jiwei
 * @description
 * @date 2024/12/23 15:18
 */
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class DebeziumRecord implements Serializable {
    @JsonProperty(value ="op")
    public String op;

    @JsonProperty(value ="before")
    public JSONObject before;

    @JsonProperty(value ="after")
    public JSONObject after;

    @JsonProperty(value ="source")
    public JSONObject source;

    @JsonProperty(value ="ts_ms")
    public Long tsMs;
}
